package cn.java.threadmodel.pipeline;

/**
 * @author 小石潭记
 * @date 2021/12/18 19:18
 * @Description: ${todo}
 */
public class TestHandler2 implements Handler {
    @Override
    public void channelRead(HandlerContext ctx, Object msg) {
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        String result = msg + "-handler2";
        System.out.println(result);
        ctx.write(result);
    }
}
